# 批处理配置
BATCH_CONFIG = {
    'size': 100,
    'timeout': 10.0
}

# Kafka配置
KAFKA_CONFIG = {
    "default": {
        'broker': 'kafka://180.76.250.147:19092,kafka://180.76.250.147:19096,kafka://180.76.250.147:19100',
        # 更改应用名称以创建新的消费者组
        'app_name': 'faust_mysql_batch_new'
    },
}
TOPIC_CONFIG = {
    "default": {
        "topic": "temp4"
    }
}

# 数据库配置
MYSQL_DATABASES = {
    # "default": {
    #     "type": "mysql",
    #     'user': 'superadmin',
    #     'password': 'Str0ngss!',
    #     'host': '192.168.1.15',
    #     'port': 3306,
    #     'database': 'medpeer',
    #     "charset": "utf8mb4"
    # },
    "default": {
        "type": "mysql",
        'user': 'medpeer',
        'password': 'medpeer',
        'host': '192.168.1.245',
        'port': 3306,
        'database': 'medicine',
        "charset": "utf8mb4"
    }
}

MONGODB_DATABASES = {
    "default": {
        "type": "mongodb",
        'user': 'medpeer',
        'password': 'medpeer',
        'auth_source': 'admin',  # 认证数据库（必须与用户创建库一致）
        'host': '192.168.1.245',
        'port': 27017,
        'database': 'raw_data',
        "charset": "utf8mb4"
    },
}
REDIS_CACHE = {
    'default': {
        'HOST': '192.168.1.243',  # 主机
        'PORT': 6379,  # 端口
        'DB': 1,  # 数据库
        'PASSWD': None,  # 密码
        'MAX_CONNECTIONS': 1000,  # 最大连接池数量
        'SOCKET_CONNECT_TIMEOUT': 300,  # 连接超时时间，单位秒
        'SOCKET_TIMEOUT': 300,  # 读写超时时间，单位秒
    },
    'redis_data_cache': {
        'HOST': '101.200.62.36',  # 主机
        'PORT': 6379,  # 端口
        'DB': 1,  # 数据库
        'PASSWD': "medpeer",  # 密码
        'MAX_CONNECTIONS': 1000,  # 最大连接池数量
        'SOCKET_CONNECT_TIMEOUT': 300,  # 连接超时时间，单位秒
        'SOCKET_TIMEOUT': 300,  # 读写超时时间，单位秒
    },
}
# ElasticSearch数据库连接
ELASTIC_CONNECTION = [
    {
        # 连接标识
        "sign": "default",
        # 服务器地址
        'host': ['192.168.1.245'],
        # 账号
        "user": "elastic",
        # 密码
        "password": "medpeer",
        # 连接协议
        "scheme": "http",
        # 服务器端口
        'port': 9200,
        # 超时时间（秒）
        "timeout": 30,
        # 错误重试次数
        "max_retries": 3,
        # 超时是否重试
        "retry_on_timeout": True,
    },
]